package com.xiaohang.springstudy.chapter1.utils;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONException;
import com.alibaba.fastjson.JSONObject;
import com.xiaohang.springstudy.chapter1.config.MyX509TrustManager;
import com.xiaohang.springstudy.chapter1.model.AccessToken;
import com.xiaohang.springstudy.chapter1.model.Menu;
import com.xiaohang.springstudy.chapter1.model.OAuthInfo;
import com.xiaohang.springstudy.chapter1.model.WxUserinfo;
import lombok.extern.slf4j.Slf4j;

import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ConnectException;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;

/**
 * 公众平台通用接口工具类
 */
@Slf4j
public class WeixinUtil {

        // 第三方用户唯一凭证
        public final static String appId = "wx71335f894797efd0";
        // 第三方用户唯一凭证密钥
        public final static String appSecret = "d524fcf5147c6c732a2270a64f5869a5";
        // 获取access_token的接口地址（GET）
        public final static String access_token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";
        // 菜单创建
        public final static String menu_create_url = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=ACCESS_TOKEN";
        // 发送模板消息
        public final static String sendtemplat_url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=ACCESS_TOKEN";
        // 获取code后，请求以下链接获取用户access_token：
        public final static String userinfotoken_url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=APPID&secret=APPSECRET&code=CODE&grant_type=authorization_code";
        // 粉丝列表
        public final static String fansi_url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN";
        // 获取用户信息
        public final static String user_url = "https://api.weixin.qq.com/sns/userinfo?access_token=ACCESS_TOKEN&openid=OPENID&lang=zh_CN";
        // 获取用户基本信息（包括UnionID机制） 粉丝列表时使用
        public final static String fansi_userinfo_url = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=ACCESS_TOKEN&openid=OPENID&lang=zh_CN";
        // 创建临时二维码ticket
        public final static String temporary_url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=ACCESS_TOKEN";
        // 创建永久二维码ticket
        public final static String permanent_url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=ACCESS_TOKEN";
        // 通过ticket换取二维码 提醒：TICKET记得进行UrlEncode
        public final static String qrcode_url = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=TICKET";
        // 获取用户增减数据 最大时间跨度7天
        public final static String getusersummary_url = "https://api.weixin.qq.com/datacube/getusersummary?access_token=ACCESS_TOKEN";
        // 获取累计用户数据 最大时间跨度7天
        public final static String getusercumulate_url = "https://api.weixin.qq.com/datacube/getusercumulate?access_token=ACCESS_TOKEN";
        // 获取jsapi_ticket
        public final static String jsapi_ticket_url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type=jsapi";
        // 创建分组 POST数据例子：{"group":{"name":"test"}}
        public final static String create_group_url = "https://api.weixin.qq.com/cgi-bin/groups/create?access_token=ACCESS_TOKEN";
        // 查询所有分组
        public final static String selete_group_url = "https://api.weixin.qq.com/cgi-bin/groups/get?access_token=ACCESS_TOKEN";
        // 查询用户所在分组 POST数据例子：{"openid":"od8XIjsmk6QdVTETa9jLtGWA6KBc"}
        public final static String selectUsers_group_url = "https://api.weixin.qq.com/cgi-bin/groups/getid?access_token=ACCESS_TOKEN";
        // 修改分组名 POST数据例子：{"group":{"id":108,"name":"test2_modify2"}}
        public final static String update_group_url = "https://api.weixin.qq.com/cgi-bin/groups/update?access_token=ACCESS_TOKEN";
        // 批量移动用户分组
        public final static String batch_group_url = "https://api.weixin.qq.com/cgi-bin/groups/members/batchupdate?access_token=ACCESS_TOKEN";
        // 获取微信卡券 api_ticket
        public final static String api_ticket_url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type=wx_card";
        // 批量查询卡券列表
        public final static String batchget_url = "https://api.weixin.qq.com/card/batchget?access_token=ACCESS_TOKEN";
        // 查询卡券详情 http请求方式: POST POST数据 {"card_id":"pFS7Fjg8kV1IdDz01r4SQwMkuCKc"}
        public final static String get_card_url = "https://api.weixin.qq.com/card/get?access_token=ACCESS_TOKEN";
        // 创建卡券二维码 ticket post请求
        public final static String create_cardTicket_url = "https://api.weixin.qq.com/card/qrcode/create?access_token=ACCESS_TOKEN";
        // 核销卡券Code接口
        public final static String delete_code_url = "https://api.weixin.qq.com/card/code/consume?access_token=ACCESS_TOKEN";
        // Code解码接口
        public final static String code_decrypt_url = "https://api.weixin.qq.com/card/code/decrypt?access_token=ACCESS_TOKEN";
        // 检测Code是否正常状态
        public final static String check_code_url = "https://api.weixin.qq.com/card/code/get?access_token=ACCESS_TOKEN";
        // 创建卡券货架接口
        public final static String create_cardhj_url = "https://api.weixin.qq.com/card/landingpage/create?access_token=ACCESS_TOKEN";
        // 获取用户已领取卡券接口
        public final static String getcardlist_url = "https://api.weixin.qq.com/card/user/getcardlist?access_token=ACCESS_TOKEN";
        //添加客服账号
        public final static String kfaccount_add_url="https://api.weixin.qq.com:9004/customservice/kfaccount/add?access_token=ACCESS_TOKEN";
        //邀请绑定客服帐号
        public final static String kfaccount_inviteworker_url="https://api.weixin.qq.com:9004/customservice/kfaccount/inviteworker?access_token=ACCESS_TOKEN";
        /**
         * 获取access_token
         *
         * @param appid
         *            凭证
         * @param appsecret
         *            密钥
         * @return
         */
        public static AccessToken getAccessToken(String appid, String appsecret) {
            AccessToken accessToken = null;
            String requestUrl = access_token_url.replace("APPID", appid).replace(
                    "APPSECRET", appsecret);
            JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
            // 如果请求成功
            if (null != jsonObject) {
                try {
                    accessToken = new AccessToken();
                    accessToken.setToken(jsonObject.getString("access_token"));
                    accessToken.setExpiresIn(jsonObject.getInteger("expires_in"));
                } catch (JSONException e) {
                    accessToken = null;
                    // 获取token失败
                    log.error("获取token失败 errcode:{} errmsg:{}",
                            jsonObject.getInteger("errcode"),
                            jsonObject.getString("errmsg"));
                }
            }
            return accessToken;
        }

        /**
         * 获取网页授权用户的token
         *
         * @param code
         * @return 2016年8月17日
         */
        public static OAuthInfo getUserToken(String code) {
            String requestUrl = userinfotoken_url.replace("APPID", appId)
                    .replace("APPSECRET", appSecret).replace("CODE", code);
            JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
            OAuthInfo oa = new OAuthInfo();
            if (null != jsonObject) {
                try {
                    oa.setAccessToken(jsonObject.getString("access_token"));
                    oa.setExpiresin(jsonObject.getInteger("expires_in").toString());
                    oa.setRefreshToken(jsonObject.getString("refresh_token"));
                    oa.setOpenid(jsonObject.getString("openid"));
                    oa.setScope(jsonObject.getString("scope"));
                } catch (JSONException e) {
                    // 获取token失败
                    log.error("网页授权获取openId失败 errcode:{} errmsg:{}",
                            jsonObject.getInteger("errcode"),
                            jsonObject.getString("errmsg"));
                }
            }
            return oa;

        }

        /**
         * 获取网页授权用户的详细信息
         *
         * @param oa
         * @return 2016年8月17日
         */
        public static WxUserinfo getWxUserInfo(OAuthInfo oa) {
            String requestUrl = user_url.replace("ACCESS_TOKEN",
                    oa.getAccessToken()).replace("OPENID", oa.getOpenid());
            JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
            WxUserinfo user = new WxUserinfo();
            if (jsonObject != null) {
                user.setOpenid(jsonObject.getString("openid"));
                user.setNickname(jsonObject.getString("nickname"));
                user.setSex(jsonObject.getString("sex"));
                user.setProvince(jsonObject.getString("province"));
                user.setCity(jsonObject.getString("city"));
                user.setCountry(jsonObject.getString("country"));
                user.setHeadimgurl(jsonObject.getString("headimgurl"));
                user.setPrivilege(jsonObject.getString("privilege"));
            }
            return user;
        }

        /**
         * 创建菜单
         *
         * @param menu
         *            菜单实例
         * @param accessToken
         *            有效的access_token
         * @return 0表示成功，其他值表示失败
         */
        public static int createMenu(Menu menu, String accessToken) {
            int result = 0;

            // 拼装创建菜单的url
            String url = menu_create_url.replace("ACCESS_TOKEN", accessToken);
            // 将菜单对象转换成json字符串
            String jsonMenu = JSONObject.toJSONString(menu);
            // 调用接口创建菜单
            JSONObject jsonObject = httpRequest(url, "POST", jsonMenu);

            if (null != jsonObject) {
                if (0 != jsonObject.getInteger("errcode")) {
                    result = jsonObject.getInteger("errcode");
                    log.error("创建菜单失败 errcode:{} errmsg:{}",
                            jsonObject.getInteger("errcode"),
                            jsonObject.getString("errmsg"));
                }
            }

            return result;
        }

        /**
         * 获取粉丝列表信息
         *
         * @param accessToken
         */
        public static JSONArray getFansList(String accessToken) {
            JSONArray arrs = new JSONArray();
            String url = fansi_url.replace("ACCESS_TOKEN", accessToken);
            JSONObject jsonObject = httpRequest(url, "GET", null);
            if (null != jsonObject) {
                JSONObject data = (JSONObject) jsonObject.get("data");
                JSONArray openidList = data.getJSONArray("openid");
                for (int i = 0; i < openidList.size(); i++) {
                    System.out.println(openidList.getString(i));
                    JSONObject obj = httpRequest(
                            fansi_userinfo_url.replace("ACCESS_TOKEN", accessToken)
                                    .replace("OPENID", openidList.getString(i)),
                            "GET", null);
                    if (obj != null) {
                        arrs.add(obj);
                    }
                }
            }
            return arrs;
        }

        /**
         * 创建二维码ticket
         *
         * @param type
         *            1=临时 ,2=永久
         * @param accessToken
         * @param expire_seconds
         *            该二维码有效时间，以秒为单位。 最大不超过2592000
         * @param scene_id
         *            场景值ID，临时二维码时为32位非0整型，永久二维码时最大值为100000
         * @return 2016年8月18日
         */
        public static JSONObject createTicket(String type, String accessToken,
                                              String expire_seconds, String scene_id) {
            String requestUrl = "";
            String jsonStr = "";
            if (type.equals("1")) {// 临时
                requestUrl = temporary_url.replace("ACCESS_TOKEN", accessToken);
                jsonStr = "{\"expire_seconds\": 604800, \"action_name\": \"QR_SCENE\", \"action_info\": {\"scene\": {\"scene_id\": 123}}}";
            } else {// 永久
                requestUrl = permanent_url.replace("ACCESS_TOKEN", accessToken);
                jsonStr = "{\"action_name\": \"QR_LIMIT_SCENE\", \"action_info\": {\"scene\": {\"scene_id\": 123}}}";
            }
            JSONObject jsonObject = httpRequest(requestUrl, "POST", jsonStr);
            return jsonObject;
        }

        /**
         * 发起https请求并获取结果
         *
         * @param requestUrl
         *            请求地址
         * @param requestMethod
         *            请求方式（GET、POST）
         * @param outputStr
         *            提交的数据
         * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
         */
        public static JSONObject httpRequest(String requestUrl,
                                             String requestMethod, String outputStr) {
            JSONObject jsonObject = null;
            StringBuffer buffer = new StringBuffer();
            try {
                // 创建SSLContext对象，并使用我们指定的信任管理器初始化
                TrustManager[] tm = { new MyX509TrustManager() };
                SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
                sslContext.init(null, tm, new java.security.SecureRandom());
                // 从上述SSLContext对象中得到SSLSocketFactory对象
                SSLSocketFactory ssf = sslContext.getSocketFactory();

                URL url = new URL(requestUrl);
                HttpsURLConnection httpUrlConn = (HttpsURLConnection) url
                        .openConnection();
                httpUrlConn.setSSLSocketFactory(ssf);

                httpUrlConn.setDoOutput(true);
                httpUrlConn.setDoInput(true);
                httpUrlConn.setUseCaches(false);
                // 设置请求方式（GET/POST）
                httpUrlConn.setRequestMethod(requestMethod);

                if ("GET".equalsIgnoreCase(requestMethod))
                    httpUrlConn.connect();

                // 当有数据需要提交时
                if (null != outputStr) {
                    OutputStream outputStream = httpUrlConn.getOutputStream();
                    // 注意编码格式，防止中文乱码
                    outputStream.write(outputStr.getBytes("UTF-8"));
                    outputStream.close();
                }

                // 将返回的输入流转换成字符串
                InputStream inputStream = httpUrlConn.getInputStream();
                InputStreamReader inputStreamReader = new InputStreamReader(
                        inputStream, "utf-8");
                BufferedReader bufferedReader = new BufferedReader(
                        inputStreamReader);

                String str = null;
                while ((str = bufferedReader.readLine()) != null) {
                    buffer.append(str);
                }
                bufferedReader.close();
                inputStreamReader.close();
                // 释放资源
                inputStream.close();
                inputStream = null;
                httpUrlConn.disconnect();
                jsonObject = JSONObject.parseObject(buffer.toString());
            } catch (ConnectException ce) {
                log.error("Weixin server connection timed out.");
            } catch (Exception e) {
                log.error("https request error:{}", e);
            }
            return jsonObject;
        }

        public static Map<String, Object> wxMsgMap(Map<String, Object> allMap,
                                                   String key, String value, String color) {
            Map<String, Object> map = new HashMap<String, Object>();
            map.put("value", value);
            map.put("color", color);
            allMap.put(key, map);
            return allMap;

        }

        /**
         * 发送模板消息
         *
         * @param accessToken
         * @param OpenId
         * @param template_id
         * @param detailUrl
         * @param map
         * @return 2016年9月19日
         */
        public static JSONObject postTemplateMsg(String accessToken, String OpenId,
                                                 String template_id, String detailUrl, Map<String, Object> map) {
            String url = sendtemplat_url.replace("ACCESS_TOKEN", accessToken);
            JSONObject jso = new JSONObject();
            jso.put("touser", OpenId);
            jso.put("template_id", template_id);
            if (detailUrl != null)
                jso.put("url", detailUrl);
            jso.put("data", map);
            return httpRequest(url, "POST", jso.toString());
        }
}
